package com.hanson.demo.queue;


import com.hanson.demo.actors.Message;

public interface TbQueueConsumer<T extends Message> {


	public void consumerMessage(String topic,String msg);

    boolean isStopped();

}
